package com.lansetech.framework.redis.peak.shaving;

public interface MessageConsumer {

    void consume(String type, String value);

    void handleFailure(String type, String value, Exception e);
}
